[INFO] cloning repository https://github.com/dennie-seth/Rust-Data-Broker-Client
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/dennie-seth/Rust-Data-Broker-Client" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fdennie-seth%2FRust-Data-Broker-Client", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fdennie-seth%2FRust-Data-Broker-Client'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] acce82842aa01a53bcdfe9a5a610f01f64d58112
[INFO] checking dennie-seth/Rust-Data-Broker-Client against master#ff647322379c48947c196639599067665ff9eb88 for pr-151539-1
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fdennie-seth%2FRust-Data-Broker-Client" "/workspace/builds/worker-2-tc1/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-2-tc1/source'...
[INFO] [stderr] done.
[INFO] started tweaking git repo https://github.com/dennie-seth/Rust-Data-Broker-Client
[INFO] finished tweaking git repo https://github.com/dennie-seth/Rust-Data-Broker-Client
[INFO] tweaked toml for git repo https://github.com/dennie-seth/Rust-Data-Broker-Client written to /workspace/builds/worker-2-tc1/source/Cargo.toml
[INFO] validating manifest of git repo https://github.com/dennie-seth/Rust-Data-Broker-Client on toolchain ff647322379c48947c196639599067665ff9eb88
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+ff647322379c48947c196639599067665ff9eb88" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate git repo https://github.com/dennie-seth/Rust-Data-Broker-Client already has a lockfile, it will not be regenerated
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+ff647322379c48947c196639599067665ff9eb88" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Updating crates.io index
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded pyo3-asyncio v0.20.0
[INFO] [stderr]   Downloaded pyo3-macros v0.20.3
[INFO] [stderr]   Downloaded pyo3-build-config v0.20.3
[INFO] [stderr]   Downloaded pyo3-macros-backend v0.20.3
[INFO] [stderr]   Downloaded pyo3-ffi v0.20.3
[INFO] [stderr]   Downloaded pyo3 v0.20.3
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-m" "1610612736" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:3a6becf2bc8dde7f3fa57ede90e4f284e72d296796fc446bbb1e2c7cc0530151" "sleep" "infinity", kill_on_drop: false }`
[INFO] [stdout] cbe2a35af7313734df3ea58006b5b6e1d60cd01cf8143812948ba0ea881eeeee
[INFO] running `Command { std: "docker" "start" "cbe2a35af7313734df3ea58006b5b6e1d60cd01cf8143812948ba0ea881eeeee", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-w" "/opt/rustwide/workdir" "--user" "0:0" "cbe2a35af7313734df3ea58006b5b6e1d60cd01cf8143812948ba0ea881eeeee" "/opt/rustwide/cargo-home/bin/cargo" "+ff647322379c48947c196639599067665ff9eb88" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "cbe2a35af7313734df3ea58006b5b6e1d60cd01cf8143812948ba0ea881eeeee", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-w" "/opt/rustwide/workdir" "--user" "0:0" "cbe2a35af7313734df3ea58006b5b6e1d60cd01cf8143812948ba0ea881eeeee" "/opt/rustwide/cargo-home/bin/cargo" "+ff647322379c48947c196639599067665ff9eb88" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr]    Compiling target-lexicon v0.12.16
[INFO] [stderr]    Compiling proc-macro2 v1.0.101
[INFO] [stderr]    Compiling unicode-ident v1.0.19
[INFO] [stderr]     Checking futures-core v0.3.31
[INFO] [stderr]    Compiling lock_api v0.4.13
[INFO] [stderr]     Checking unindent v0.2.4
[INFO] [stderr]    Compiling indoc v2.0.7
[INFO] [stderr]     Checking parking_lot_core v0.9.11
[INFO] [stderr]     Checking mio v1.0.4
[INFO] [stderr]     Checking futures-channel v0.3.31
[INFO] [stderr]     Checking parking_lot v0.12.4
[INFO] [stderr]    Compiling quote v1.0.41
[INFO] [stderr]    Compiling pyo3-build-config v0.20.3
[INFO] [stderr]    Compiling syn v2.0.106
[INFO] [stderr]    Compiling pyo3-ffi v0.20.3
[INFO] [stderr]    Compiling pyo3 v0.20.3
[INFO] [stderr]    Compiling pyo3-macros-backend v0.20.3
[INFO] [stderr]    Compiling futures-macro v0.3.31
[INFO] [stderr]    Compiling tokio-macros v2.6.0
[INFO] [stderr]     Checking tokio v1.48.0
[INFO] [stderr]     Checking futures-util v0.3.31
[INFO] [stderr]    Compiling pyo3-macros v0.20.3
[INFO] [stderr]     Checking futures-executor v0.3.31
[INFO] [stderr]     Checking futures v0.3.31
[INFO] [stderr]     Checking pyo3-asyncio v0.20.0
[INFO] [stderr]     Checking DataBrokerClient v0.3.1 (/opt/rustwide/workdir)
[INFO] [stdout] warning: unused import: `pyo3::prelude`
[INFO] [stdout]  --> src/net/client.rs:3:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | use pyo3::prelude::*;
[INFO] [stdout]   |     ^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `pyo3::prelude`
[INFO] [stdout]  --> src/net/client.rs:3:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | use pyo3::prelude::*;
[INFO] [stdout]   |     ^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type `Response` is more private than the item `ResponseMessage::new`
[INFO] [stdout]    --> src/net/client.rs:194:5
[INFO] [stdout]     |
[INFO] [stdout] 194 |     pub(crate) fn new(status: Response, payload_size: u64, payload: Vec<u8>) -> Self {
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ associated function `ResponseMessage::new` is reachable at visibility `pub(crate)`
[INFO] [stdout]     |
[INFO] [stdout] note: but type `Response` is only usable at visibility `pub(self)`
[INFO] [stdout]    --> src/net/client.rs:149:1
[INFO] [stdout]     |
[INFO] [stdout] 149 | enum Response {
[INFO] [stdout]     | ^^^^^^^^^^^^^
[INFO] [stdout]     = note: `#[warn(private_interfaces)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `META_SIZE` is never used
[INFO] [stdout]   --> src/net/client.rs:10:7
[INFO] [stdout]    |
[INFO] [stdout] 10 | const META_SIZE: usize = 56;
[INFO] [stdout]    |       ^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `stream` and `client_id` are never read
[INFO] [stdout]   --> src/net/client.rs:14:5
[INFO] [stdout]    |
[INFO] [stdout] 13 | pub struct BrokerClient {
[INFO] [stdout]    |            ------------ fields in this struct
[INFO] [stdout] 14 |     stream: Arc<Mutex<TcpStream>>,
[INFO] [stdout]    |     ^^^^^^
[INFO] [stdout] 15 |     client_id: u128,
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `BrokerClient` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_list_response` is never used
[INFO] [stdout]   --> src/net/client.rs:57:8
[INFO] [stdout]    |
[INFO] [stdout] 57 | pub fn parse_list_response(payload: &[u8]) -> Vec<MessageMeta> {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_dequeue_response` is never used
[INFO] [stdout]   --> src/net/client.rs:62:8
[INFO] [stdout]    |
[INFO] [stdout] 62 | pub fn parse_dequeue_response(payload: &[u8]) -> Result<(MessageMeta, Vec<u8>), std::io::Error> {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_stats_response` is never used
[INFO] [stdout]   --> src/net/client.rs:77:8
[INFO] [stdout]    |
[INFO] [stdout] 77 | pub fn parse_stats_response(payload: &[u8]) -> Result<Vec<QueueStat>, std::io::Error> {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `Request` is never used
[INFO] [stdout]    --> src/net/client.rs:114:10
[INFO] [stdout]     |
[INFO] [stdout] 114 | pub enum Request {
[INFO] [stdout]     |          ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `from_u8` is never used
[INFO] [stdout]    --> src/net/client.rs:129:12
[INFO] [stdout]     |
[INFO] [stdout] 128 | impl Request {
[INFO] [stdout]     | ------------ associated function in this implementation
[INFO] [stdout] 129 |     pub fn from_u8(value: u8) -> Result<Self, std::io::Error> {
[INFO] [stdout]     |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `Response` is never used
[INFO] [stdout]    --> src/net/client.rs:149:6
[INFO] [stdout]     |
[INFO] [stdout] 149 | enum Response {
[INFO] [stdout]     |      ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `from_u8` is never used
[INFO] [stdout]    --> src/net/client.rs:154:19
[INFO] [stdout]     |
[INFO] [stdout] 153 | impl Response {
[INFO] [stdout]     | ------------- associated function in this implementation
[INFO] [stdout] 154 |     pub(crate) fn from_u8(value: u8) -> Result<Self, std::io::Error> {
[INFO] [stdout]     |                   ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `RequestMessage` is never constructed
[INFO] [stdout]    --> src/net/client.rs:164:19
[INFO] [stdout]     |
[INFO] [stdout] 164 | pub(crate) struct RequestMessage {
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `as_bytes` is never used
[INFO] [stdout]    --> src/net/client.rs:172:19
[INFO] [stdout]     |
[INFO] [stdout] 171 | impl RequestMessage {
[INFO] [stdout]     | ------------------- method in this implementation
[INFO] [stdout] 172 |     pub(crate) fn as_bytes(&self) -> Vec<u8> {
[INFO] [stdout]     |                   ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ResponseMessage` is never constructed
[INFO] [stdout]    --> src/net/client.rs:188:19
[INFO] [stdout]     |
[INFO] [stdout] 188 | pub(crate) struct ResponseMessage {
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]    --> src/net/client.rs:194:19
[INFO] [stdout]     |
[INFO] [stdout] 193 | impl ResponseMessage {
[INFO] [stdout]     | -------------------- associated function in this implementation
[INFO] [stdout] 194 |     pub(crate) fn new(status: Response, payload_size: u64, payload: Vec<u8>) -> Self {
[INFO] [stdout]     |                   ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `error_code_message` is never used
[INFO] [stdout]    --> src/net/client.rs:202:4
[INFO] [stdout]     |
[INFO] [stdout] 202 | fn error_code_message(code: u16) -> &'static str {
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_error_payload` is never used
[INFO] [stdout]    --> src/net/client.rs:227:4
[INFO] [stdout]     |
[INFO] [stdout] 227 | fn parse_error_payload(payload: &[u8]) -> String {
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_message` is never used
[INFO] [stdout]    --> src/net/client.rs:235:4
[INFO] [stdout]     |
[INFO] [stdout] 235 | fn parse_message(buffer: &mut BytesMut) -> Result<ResponseMessage, std::io::Error> {
[INFO] [stdout]     |    ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `send` and `receive` are never used
[INFO] [stdout]    --> src/net/client.rs:257:25
[INFO] [stdout]     |
[INFO] [stdout] 246 | impl BrokerClient {
[INFO] [stdout]     | ----------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 257 |     pub(crate) async fn send(&self, command: Request, payload: Vec<u8>, queue_name: &str) -> Result<(), std::io::Error> {
[INFO] [stdout]     |                         ^^^^
[INFO] [stdout] ...
[INFO] [stdout] 271 |     pub(crate) async fn receive(&self) -> Result<Vec<u8>, std::io::Error> {
[INFO] [stdout]     |                         ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `client_send` is never used
[INFO] [stdout]    --> src/net/client.rs:302:14
[INFO] [stdout]     |
[INFO] [stdout] 302 | pub async fn client_send(client: Arc<Mutex<BrokerClient>>, command: u8, payload: Vec<u8>, queue_name: &str) -> Result<Vec<u8>, std:...
[INFO] [stdout]     |              ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type `Response` is more private than the item `ResponseMessage::new`
[INFO] [stdout]    --> src/net/client.rs:194:5
[INFO] [stdout]     |
[INFO] [stdout] 194 |     pub(crate) fn new(status: Response, payload_size: u64, payload: Vec<u8>) -> Self {
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ associated function `ResponseMessage::new` is reachable at visibility `pub(crate)`
[INFO] [stdout]     |
[INFO] [stdout] note: but type `Response` is only usable at visibility `pub(self)`
[INFO] [stdout]    --> src/net/client.rs:149:1
[INFO] [stdout]     |
[INFO] [stdout] 149 | enum Response {
[INFO] [stdout]     | ^^^^^^^^^^^^^
[INFO] [stdout]     = note: `#[warn(private_interfaces)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `META_SIZE` is never used
[INFO] [stdout]   --> src/net/client.rs:10:7
[INFO] [stdout]    |
[INFO] [stdout] 10 | const META_SIZE: usize = 56;
[INFO] [stdout]    |       ^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `stream` and `client_id` are never read
[INFO] [stdout]   --> src/net/client.rs:14:5
[INFO] [stdout]    |
[INFO] [stdout] 13 | pub struct BrokerClient {
[INFO] [stdout]    |            ------------ fields in this struct
[INFO] [stdout] 14 |     stream: Arc<Mutex<TcpStream>>,
[INFO] [stdout]    |     ^^^^^^
[INFO] [stdout] 15 |     client_id: u128,
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `BrokerClient` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_list_response` is never used
[INFO] [stdout]   --> src/net/client.rs:57:8
[INFO] [stdout]    |
[INFO] [stdout] 57 | pub fn parse_list_response(payload: &[u8]) -> Vec<MessageMeta> {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_dequeue_response` is never used
[INFO] [stdout]   --> src/net/client.rs:62:8
[INFO] [stdout]    |
[INFO] [stdout] 62 | pub fn parse_dequeue_response(payload: &[u8]) -> Result<(MessageMeta, Vec<u8>), std::io::Error> {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_stats_response` is never used
[INFO] [stdout]   --> src/net/client.rs:77:8
[INFO] [stdout]    |
[INFO] [stdout] 77 | pub fn parse_stats_response(payload: &[u8]) -> Result<Vec<QueueStat>, std::io::Error> {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `Request` is never used
[INFO] [stdout]    --> src/net/client.rs:114:10
[INFO] [stdout]     |
[INFO] [stdout] 114 | pub enum Request {
[INFO] [stdout]     |          ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `from_u8` is never used
[INFO] [stdout]    --> src/net/client.rs:129:12
[INFO] [stdout]     |
[INFO] [stdout] 128 | impl Request {
[INFO] [stdout]     | ------------ associated function in this implementation
[INFO] [stdout] 129 |     pub fn from_u8(value: u8) -> Result<Self, std::io::Error> {
[INFO] [stdout]     |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `Response` is never used
[INFO] [stdout]    --> src/net/client.rs:149:6
[INFO] [stdout]     |
[INFO] [stdout] 149 | enum Response {
[INFO] [stdout]     |      ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `from_u8` is never used
[INFO] [stdout]    --> src/net/client.rs:154:19
[INFO] [stdout]     |
[INFO] [stdout] 153 | impl Response {
[INFO] [stdout]     | ------------- associated function in this implementation
[INFO] [stdout] 154 |     pub(crate) fn from_u8(value: u8) -> Result<Self, std::io::Error> {
[INFO] [stdout]     |                   ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `RequestMessage` is never constructed
[INFO] [stdout]    --> src/net/client.rs:164:19
[INFO] [stdout]     |
[INFO] [stdout] 164 | pub(crate) struct RequestMessage {
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `as_bytes` is never used
[INFO] [stdout]    --> src/net/client.rs:172:19
[INFO] [stdout]     |
[INFO] [stdout] 171 | impl RequestMessage {
[INFO] [stdout]     | ------------------- method in this implementation
[INFO] [stdout] 172 |     pub(crate) fn as_bytes(&self) -> Vec<u8> {
[INFO] [stdout]     |                   ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ResponseMessage` is never constructed
[INFO] [stdout]    --> src/net/client.rs:188:19
[INFO] [stdout]     |
[INFO] [stdout] 188 | pub(crate) struct ResponseMessage {
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]    --> src/net/client.rs:194:19
[INFO] [stdout]     |
[INFO] [stdout] 193 | impl ResponseMessage {
[INFO] [stdout]     | -------------------- associated function in this implementation
[INFO] [stdout] 194 |     pub(crate) fn new(status: Response, payload_size: u64, payload: Vec<u8>) -> Self {
[INFO] [stdout]     |                   ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `error_code_message` is never used
[INFO] [stdout]    --> src/net/client.rs:202:4
[INFO] [stdout]     |
[INFO] [stdout] 202 | fn error_code_message(code: u16) -> &'static str {
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_error_payload` is never used
[INFO] [stdout]    --> src/net/client.rs:227:4
[INFO] [stdout]     |
[INFO] [stdout] 227 | fn parse_error_payload(payload: &[u8]) -> String {
[INFO] [stdout]     |    ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_message` is never used
[INFO] [stdout]    --> src/net/client.rs:235:4
[INFO] [stdout]     |
[INFO] [stdout] 235 | fn parse_message(buffer: &mut BytesMut) -> Result<ResponseMessage, std::io::Error> {
[INFO] [stdout]     |    ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `send` and `receive` are never used
[INFO] [stdout]    --> src/net/client.rs:257:25
[INFO] [stdout]     |
[INFO] [stdout] 246 | impl BrokerClient {
[INFO] [stdout]     | ----------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 257 |     pub(crate) async fn send(&self, command: Request, payload: Vec<u8>, queue_name: &str) -> Result<(), std::io::Error> {
[INFO] [stdout]     |                         ^^^^
[INFO] [stdout] ...
[INFO] [stdout] 271 |     pub(crate) async fn receive(&self) -> Result<Vec<u8>, std::io::Error> {
[INFO] [stdout]     |                         ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `client_send` is never used
[INFO] [stdout]    --> src/net/client.rs:302:14
[INFO] [stdout]     |
[INFO] [stdout] 302 | pub async fn client_send(client: Arc<Mutex<BrokerClient>>, command: u8, payload: Vec<u8>, queue_name: &str) -> Result<Vec<u8>, std:...
[INFO] [stdout]     |              ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `pyo3::prelude`
[INFO] [stdout]  --> src/net/client.rs:3:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | use pyo3::prelude::*;
[INFO] [stdout]   |     ^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `pyo3::prelude`
[INFO] [stdout]  --> src/net/client.rs:3:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | use pyo3::prelude::*;
[INFO] [stdout]   |     ^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning[E0133]: call to unsafe function `pyo3::impl_::extract_argument::unwrap_required_argument` is unsafe and requires unsafe block
[INFO] [stdout]   --> src/lib.rs:17:40
[INFO] [stdout]    |
[INFO] [stdout] 17 | unsafe fn connect(py: Python<'_>, url: String) -> PyResult<&PyAny> {
[INFO] [stdout]    |                                        ^^^^^^ call to unsafe function
[INFO] [stdout]    |
[INFO] [stdout]    = note: consult the function's documentation for information on how to avoid undefined behavior
[INFO] [stdout]    = note: for more information, see <https://doc.rust-lang.org/edition-guide/rust-2024/unsafe-op-in-unsafe-fn.html>
[INFO] [stdout]    = note: `#[warn(unsafe_op_in_unsafe_fn)]` (part of `#[warn(rust_2024_compatibility)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning[E0133]: call to unsafe function `pyo3::impl_::extract_argument::unwrap_required_argument` is unsafe and requires unsafe block
[INFO] [stdout]   --> src/lib.rs:33:46
[INFO] [stdout]    |
[INFO] [stdout] 33 | unsafe fn send<'py>(py: Python<'py>, client: &PyBrokerClient, command: u8, payload: Vec<u8>, queue_name: String) -> PyResult<&'py Py...
[INFO] [stdout]    |                                              ^^^^^^^^^^^^^^^ call to unsafe function
[INFO] [stdout]    |
[INFO] [stdout]    = note: consult the function's documentation for information on how to avoid undefined behavior
[INFO] [stdout]    = note: for more information, see <https://doc.rust-lang.org/edition-guide/rust-2024/unsafe-op-in-unsafe-fn.html>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning[E0133]: call to unsafe function `pyo3::impl_::extract_argument::unwrap_required_argument` is unsafe and requires unsafe block
[INFO] [stdout]   --> src/lib.rs:33:72
[INFO] [stdout]    |
[INFO] [stdout] 33 | unsafe fn send<'py>(py: Python<'py>, client: &PyBrokerClient, command: u8, payload: Vec<u8>, queue_name: String) -> PyResult<&'py Py...
[INFO] [stdout]    |                                                                        ^^ call to unsafe function
[INFO] [stdout]    |
[INFO] [stdout]    = note: consult the function's documentation for information on how to avoid undefined behavior
[INFO] [stdout]    = note: for more information, see <https://doc.rust-lang.org/edition-guide/rust-2024/unsafe-op-in-unsafe-fn.html>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning[E0133]: call to unsafe function `pyo3::impl_::extract_argument::unwrap_required_argument` is unsafe and requires unsafe block
[INFO] [stdout]   --> src/lib.rs:33:85
[INFO] [stdout]    |
[INFO] [stdout] 33 | unsafe fn send<'py>(py: Python<'py>, client: &PyBrokerClient, command: u8, payload: Vec<u8>, queue_name: String) -> PyResult<&'py Py...
[INFO] [stdout]    |                                                                                     ^^^^^^^ call to unsafe function
[INFO] [stdout]    |
[INFO] [stdout]    = note: consult the function's documentation for information on how to avoid undefined behavior
[INFO] [stdout]    = note: for more information, see <https://doc.rust-lang.org/edition-guide/rust-2024/unsafe-op-in-unsafe-fn.html>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning[E0133]: call to unsafe function `pyo3::impl_::extract_argument::unwrap_required_argument` is unsafe and requires unsafe block
[INFO] [stdout]   --> src/lib.rs:33:106
[INFO] [stdout]    |
[INFO] [stdout] 33 | ...ient, command: u8, payload: Vec<u8>, queue_name: String) -> PyResult<&'py PyAny> {
[INFO] [stdout]    |                                                     ^^^^^^ call to unsafe function
[INFO] [stdout]    |
[INFO] [stdout]    = note: consult the function's documentation for information on how to avoid undefined behavior
[INFO] [stdout]    = note: for more information, see <https://doc.rust-lang.org/edition-guide/rust-2024/unsafe-op-in-unsafe-fn.html>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `py`
[INFO] [stdout]   --> src/lib.rs:81:23
[INFO] [stdout]    |
[INFO] [stdout] 81 | fn data_broker_client(py: Python<'_>, m: &PyModule) -> PyResult<()> {
[INFO] [stdout]    |                       ^^ help: if this is intentional, prefix it with an underscore: `_py`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning[E0133]: call to unsafe function `pyo3::impl_::extract_argument::unwrap_required_argument` is unsafe and requires unsafe block
[INFO] [stdout]   --> src/lib.rs:17:40
[INFO] [stdout]    |
[INFO] [stdout] 17 | unsafe fn connect(py: Python<'_>, url: String) -> PyResult<&PyAny> {
[INFO] [stdout]    |                                        ^^^^^^ call to unsafe function
[INFO] [stdout]    |
[INFO] [stdout]    = note: consult the function's documentation for information on how to avoid undefined behavior
[INFO] [stdout]    = note: for more information, see <https://doc.rust-lang.org/edition-guide/rust-2024/unsafe-op-in-unsafe-fn.html>
[INFO] [stdout]    = note: `#[warn(unsafe_op_in_unsafe_fn)]` (part of `#[warn(rust_2024_compatibility)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type `Response` is more private than the item `ResponseMessage::new`
[INFO] [stdout]    --> src/net/client.rs:194:5
[INFO] [stdout]     |
[INFO] [stdout] 194 |     pub(crate) fn new(status: Response, payload_size: u64, payload: Vec<u8>) -> Self {
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ associated function `ResponseMessage::new` is reachable at visibility `pub(crate)`
[INFO] [stdout]     |
[INFO] [stdout] note: but type `Response` is only usable at visibility `pub(self)`
[INFO] [stdout]    --> src/net/client.rs:149:1
[INFO] [stdout]     |
[INFO] [stdout] 149 | enum Response {
[INFO] [stdout]     | ^^^^^^^^^^^^^
[INFO] [stdout]     = note: `#[warn(private_interfaces)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `status` and `payload_size` are never read
[INFO] [stdout]    --> src/net/client.rs:189:5
[INFO] [stdout]     |
[INFO] [stdout] 188 | pub(crate) struct ResponseMessage {
[INFO] [stdout]     |                   --------------- fields in this struct
[INFO] [stdout] 189 |     status: Response,
[INFO] [stdout]     |     ^^^^^^
[INFO] [stdout] 190 |     payload_size: u64,
[INFO] [stdout]     |     ^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `ResponseMessage` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout]     = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning[E0133]: call to unsafe function `pyo3::impl_::extract_argument::unwrap_required_argument` is unsafe and requires unsafe block
[INFO] [stdout]   --> src/lib.rs:33:46
[INFO] [stdout]    |
[INFO] [stdout] 33 | unsafe fn send<'py>(py: Python<'py>, client: &PyBrokerClient, command: u8, payload: Vec<u8>, queue_name: String) -> PyResult<&'py Py...
[INFO] [stdout]    |                                              ^^^^^^^^^^^^^^^ call to unsafe function
[INFO] [stdout]    |
[INFO] [stdout]    = note: consult the function's documentation for information on how to avoid undefined behavior
[INFO] [stdout]    = note: for more information, see <https://doc.rust-lang.org/edition-guide/rust-2024/unsafe-op-in-unsafe-fn.html>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning[E0133]: call to unsafe function `pyo3::impl_::extract_argument::unwrap_required_argument` is unsafe and requires unsafe block
[INFO] [stdout]   --> src/lib.rs:33:72
[INFO] [stdout]    |
[INFO] [stdout] 33 | unsafe fn send<'py>(py: Python<'py>, client: &PyBrokerClient, command: u8, payload: Vec<u8>, queue_name: String) -> PyResult<&'py Py...
[INFO] [stdout]    |                                                                        ^^ call to unsafe function
[INFO] [stdout]    |
[INFO] [stdout]    = note: consult the function's documentation for information on how to avoid undefined behavior
[INFO] [stdout]    = note: for more information, see <https://doc.rust-lang.org/edition-guide/rust-2024/unsafe-op-in-unsafe-fn.html>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning[E0133]: call to unsafe function `pyo3::impl_::extract_argument::unwrap_required_argument` is unsafe and requires unsafe block
[INFO] [stdout]   --> src/lib.rs:33:85
[INFO] [stdout]    |
[INFO] [stdout] 33 | unsafe fn send<'py>(py: Python<'py>, client: &PyBrokerClient, command: u8, payload: Vec<u8>, queue_name: String) -> PyResult<&'py Py...
[INFO] [stdout]    |                                                                                     ^^^^^^^ call to unsafe function
[INFO] [stdout]    |
[INFO] [stdout]    = note: consult the function's documentation for information on how to avoid undefined behavior
[INFO] [stdout]    = note: for more information, see <https://doc.rust-lang.org/edition-guide/rust-2024/unsafe-op-in-unsafe-fn.html>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning[E0133]: call to unsafe function `pyo3::impl_::extract_argument::unwrap_required_argument` is unsafe and requires unsafe block
[INFO] [stdout]   --> src/lib.rs:33:106
[INFO] [stdout]    |
[INFO] [stdout] 33 | ...ient, command: u8, payload: Vec<u8>, queue_name: String) -> PyResult<&'py PyAny> {
[INFO] [stdout]    |                                                     ^^^^^^ call to unsafe function
[INFO] [stdout]    |
[INFO] [stdout]    = note: consult the function's documentation for information on how to avoid undefined behavior
[INFO] [stdout]    = note: for more information, see <https://doc.rust-lang.org/edition-guide/rust-2024/unsafe-op-in-unsafe-fn.html>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] For more information about this error, try `rustc --explain E0133`.
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `py`
[INFO] [stdout]   --> src/lib.rs:81:23
[INFO] [stdout]    |
[INFO] [stdout] 81 | fn data_broker_client(py: Python<'_>, m: &PyModule) -> PyResult<()> {
[INFO] [stdout]    |                       ^^ help: if this is intentional, prefix it with an underscore: `_py`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type `Response` is more private than the item `ResponseMessage::new`
[INFO] [stdout]    --> src/net/client.rs:194:5
[INFO] [stdout]     |
[INFO] [stdout] 194 |     pub(crate) fn new(status: Response, payload_size: u64, payload: Vec<u8>) -> Self {
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ associated function `ResponseMessage::new` is reachable at visibility `pub(crate)`
[INFO] [stdout]     |
[INFO] [stdout] note: but type `Response` is only usable at visibility `pub(self)`
[INFO] [stdout]    --> src/net/client.rs:149:1
[INFO] [stdout]     |
[INFO] [stdout] 149 | enum Response {
[INFO] [stdout]     | ^^^^^^^^^^^^^
[INFO] [stdout]     = note: `#[warn(private_interfaces)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `status` and `payload_size` are never read
[INFO] [stdout]    --> src/net/client.rs:189:5
[INFO] [stdout]     |
[INFO] [stdout] 188 | pub(crate) struct ResponseMessage {
[INFO] [stdout]     |                   --------------- fields in this struct
[INFO] [stdout] 189 |     status: Response,
[INFO] [stdout]     |     ^^^^^^
[INFO] [stdout] 190 |     payload_size: u64,
[INFO] [stdout]     |     ^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `ResponseMessage` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout]     = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] For more information about this error, try `rustc --explain E0133`.
[INFO] [stdout] 
[INFO] [stderr]     Finished `dev` profile [unoptimized + debuginfo] target(s) in 17.65s
[INFO] running `Command { std: "docker" "inspect" "cbe2a35af7313734df3ea58006b5b6e1d60cd01cf8143812948ba0ea881eeeee", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "cbe2a35af7313734df3ea58006b5b6e1d60cd01cf8143812948ba0ea881eeeee", kill_on_drop: false }`
[INFO] [stdout] cbe2a35af7313734df3ea58006b5b6e1d60cd01cf8143812948ba0ea881eeeee
